// 1 导入nodejs-websocket包
const ws = require('nodejs-websocket');
const POST = 3000;

// 2 创建一个server
// 2.1 如果处理用户的请求
// 每次只要用用户连接，就会执行该函数，会给当前连接的用户创建一个connect对象
const server = ws.createServer(connect =>{
    console.log("有新用户连接了websocket服务")
    // 每当接受到用户发来的数据，text方法就会被触发
    connect.on("text",data=>{
        console.log("接受到了用户发过来的消息：",data)
        // 给用户一个相应数据
        // 对用户发过来的数据进行处理，把小写转换成大写，而且拼接一些内容
        connect.send(data.toUpperCase()+"!!!!")
    }) 

    // 2.2 监听websocket断开，close事件就会触发
    connect.on("close",()=>{
        console.log("websocket链接断开了")
    })
    // 注册一个error事件处理用户断开产生的错误信息
    connect.on("error",()=>{
        console.log("用户链接断开导致的异常")
    })

})



// 监听服务端口
server.listen(POST,()=>{
    console.log("websocket服务启动成功！监听的端口是："+POST)
})